380273826d05913d4b80b73e0db2ea49711b17c7,test/pig/org/apache/cassandra/pig/ThriftColumnFamilyDataTypeTest.java,ThriftColumnFamilyDataTypeTest,testCassandraStorageDataType,#,127

Before Change


        //col_uft8: (name: chararray,value: chararray),
        //col_uuid: (name: chararray,value: chararray),
        //columns: {(name: chararray,value: chararray)}}
        Iterator<Tuple> it = pig.openIterator("rows");
        if (it.hasNext()) {
            Tuple t = it.next();
            Assert.assertEquals(t.get(0), "foo");
            Tuple column = (Tuple) t.get(1);
            Assert.assertEquals(column.get(1), "ascii");
            column = (Tuple) t.get(2);
            Assert.assertEquals(column.get(1), false);
            column = (Tuple) t.get(3);
            Assert.assertEquals(column.get(1), new DataByteArray(Hex.hexToBytes("DEADBEEF")));
            column = (Tuple) t.get(4);
            Assert.assertEquals(column.get(1), 1296705900000L);
            column = (Tuple) t.get(5);
            Assert.assertEquals(column.get(1), "23.345");
            column = (Tuple) t.get(6);
            Assert.assertEquals(column.get(1), 2.7182818284590451d);
            column = (Tuple) t.get(7);
            Assert.assertEquals(column.get(1), 23.45f);
            column = (Tuple) t.get(8);
            Assert.assertEquals(column.get(1), "127.0.0.1");
            column = (Tuple) t.get(9);
            Assert.assertEquals(column.get(1), 23);
            column = (Tuple) t.get(10);
            Assert.assertEquals(column.get(1), 12345);
            column = (Tuple) t.get(11);
            Assert.assertEquals(column.get(1), new DataByteArray((TimeUUIDType.instance.fromString("e23f450f-53a6-11e2-7f7f-7f7f7f7f7f77").array())));
            column = (Tuple) t.get(12);
            Assert.assertEquals(column.get(1), 12345678L);
            column = (Tuple) t.get(13);
            Assert.assertEquals(column.get(1), new DataByteArray((TimeUUIDType.instance.fromString("e23f450f-53a6-11e2-7f7f-7f7f7f7f7f7f").array())));
            column = (Tuple) t.get(14);

After Change


        NoSuchFieldException, IllegalAccessException, InstantiationException
    {
        pig.registerQuery("rows = LOAD 'cassandra://thrift_ks/some_app?" + defaultParameters + "' USING CassandraStorage();");
        Tuple t = pig.openIterator("rows").next();

        // key
        assertEquals("foo", t.get(0));

        // col_ascii
        Tuple column = (Tuple) t.get(1);
        assertEquals("ascii", column.get(1));

        // col_bigint
        column = (Tuple) t.get(2);
        assertEquals(12345678L, column.get(1));

        // col_blob
        column = (Tuple) t.get(3);
        assertEquals(new DataByteArray(Hex.hexToBytes("DEADBEEF")), column.get(1));

        // col_boolean
        column = (Tuple) t.get(4);
        assertEquals(false, column.get(1));

        // col_decimal
        column = (Tuple) t.get(5);
        assertEquals("23.345", column.get(1));

        // col_double
        column = (Tuple) t.get(6);
        assertEquals(2.7182818284590451d, column.get(1));

        // col_float
        column = (Tuple) t.get(7);
        assertEquals(23.45f, column.get(1));

        // col_inet
        column = (Tuple) t.get(8);
        assertEquals("127.0.0.1", column.get(1));

        // col_int
        column = (Tuple) t.get(9);
        assertEquals(23, column.get(1));

        // col_text
        column = (Tuple) t.get(10);
        assertEquals("hello", column.get(1));

        // col_timestamp
        column = (Tuple) t.get(11);
        assertEquals(1296705900000L, column.get(1));

        // col_timeuuid
        column = (Tuple) t.get(12);
        assertEquals(new DataByteArray((TimeUUIDType.instance.fromString("e23f450f-53a6-11e2-7f7f-7f7f7f7f7f7f").array())), column.get(1));

        // col_uuid
        column = (Tuple) t.get(13);
        assertEquals(new DataByteArray((UUIDType.instance.fromString("550e8400-e29b-41d4-a716-446655440000").array())), column.get(1));

        // col_varint
        column = (Tuple) t.get(14);
        assertEquals(12345, column.get(1));

        pig.registerQuery("cc_rows = LOAD 'cassandra://thrift_ks/cc?" + defaultParameters + "' USING CassandraStorage();");
        t = pig.openIterator("cc_rows").next();